﻿using Digitalmes.Models;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Digitalmes.Services
{
    public interface IMQTT
    {
        public void PublishMessage(string topic, string payload);

        public  Task PublishMessageAsync(string topic, string payload);


        public void Subscribe(string topic, Func<MqttMessage, Task> handler,
            MQTTnet.Protocol.MqttQualityOfServiceLevel qos);

        public void Unsubscribe(string topic);
    }
}
